package com.skygrass.caesar.consumer.mq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(MessageReceiver.class)
public class MessageConsumer
{
	private static final Logger log = LoggerFactory.getLogger(MessageConsumer.class);

	@StreamListener("go-to-shanghai")
	public void getShangHai(Object playload)
	{
		log.info("get from go-to-shanghai");
	}

	@StreamListener("go-to-shanghai")
	public void getShangHaiOther(Object playload)
	{
		log.info("get from go-to-shanghai other");
	}

	@StreamListener("go-to-beijing")
	public void getBeiJing(Object playload)
	{
		log.info("get from go-to-beijing");
	}
}
